package com.example.messagingrocketmq.simple;

import org.apache.rocketmq.acl.common.AclClientRPCHook;
import org.apache.rocketmq.acl.common.SessionCredentials;
import org.apache.rocketmq.remoting.RPCHook;

/**
 * @author caiwl
 * @date 2021/1/15 11:42
 */
public class Acl {
    public static RPCHook getAclRPCHook() {
        return new AclClientRPCHook(new SessionCredentials("RocketMQ","12345678"));
//        return new AclClientRPCHook(new SessionCredentials("rocketmq2","12345678"));
    }
}
